package git.soulbgm;

/**
 * @author SoulBGM
 * @version 1.0
 * @date 2019/8/13 17:31
 */
public class Test {

    public static void main(String[] args) throws InterruptedException {
        Flusher<String> flusher = new Flusher<>("test", 60, 5, new PrintOutProcessor());

        for (int i = 0; i < 1003; i++) {
            flusher.add(String.valueOf(i));
//            Thread.sleep(10);
        }
    }

}
